package pers.cz.postgirl.core.connect.kafka;


import com.oracle.jrockit.jfr.Producer;

import pers.cz.postgirl.core.connect.Connection;

/**
 * @program: postgirl-collection-client
 * @description: Kafka连接实现
 * @author: Cheng Zhi
 * @create: 2022-08-01 17:10
 **/
public class KafkaConnection extends Connection {

    @Override
    public void close() {

    }

    @Override
    public void insert(String key, byte[] content) {

    }

    @Override
    public String get(String key) {
        return null;
    }

    @Override
    public byte[] getBytes(String key) {
        return new byte[0];
    }

    @Override
    public Long autoIncrement(String key) {
        return null;
    }

    @Override
    public void expire(String key, Integer time) {

    }

    @Override
    public void realInsert(String content) {

    }

    @Override
    public void realSet(String key, String value) {

    }

    @Override
    public void realInsert(String key, String content) {

    }

    @Override
    public void realInsert(String ip, String fileName, String content) {

    }
}
